package com.sxhuayuan.parking.queue;

import com.sxhuayuan.parking.queue.msg.QueueMsg;

/**
 * 消息队列接口
 * 
 * @author gy
 *
 */
public interface QueueService {

	/**
	 * 添加延迟任务到延迟队列
	 * 
	 * @param delayQueueMsg
	 */
	void push(QueueMsg delayQueueMsg);

	/**
	 * 删除延迟队列任务
	 * 
	 * @param delayQueueMsgId
	 */
	void delete(long delayQueueMsgId);

	/**
	 * 如果msg.ttr大于0，则消息处理后需要调用此接口来标记消息已处理完成，否则超时ttr后会重新加入ready队列
	 * 
	 * @param delayQueueMsgId
	 */
	void finish(long delayQueueMsgId);
}